package cn.com.daimajiangxin.flink;

import java.io.Serializable;

/**
 * 简化版 TaxiFare 事件模型。
 * 字段：driverId（司机ID）、eventTime（事件时间，毫秒）、tip（小费，浮点）
 */
public class TaxiFare implements Serializable {
    private static final long serialVersionUID = 1L;
    public long driverId;
    public long eventTime; // epoch millis
    public float tip;

    public TaxiFare() {
    }

    public TaxiFare(long driverId, long eventTime, float tip) {
        this.driverId = driverId;
        this.eventTime = eventTime;
        this.tip = tip;
    }

    public long getDriverId() {
        return driverId;
    }

    public long getEventTime() {
        return eventTime;
    }

    public float getTip() {
        return tip;
    }

    @Override
    public String toString() {
        return "TaxiFare{" +
                "driverId=" + driverId +
                ", eventTime=" + eventTime +
                ", tip=" + tip +
                '}';
    }
}
